<?php

/**
 * Copyright 2019 Huawei Technologies Co.,Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
 * this file except in compliance with the License.  You may obtain a copy of the
 * License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 * CONDITIONS OF ANY KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations under the License.
 *
 */

/**
 * This sample demonstrates how to list objects under a specified folder of a bucket
 * from OBS using the OBS SDK for PHP.
 */
if (file_exists('vendor/autoload.php')) {
    require 'vendor/autoload.php';
} else {
    require '../vendor/autoload.php'; // sample env
}

if (file_exists('obs-autoloader.php')) {
    require 'obs-autoloader.php';
} else {
    require '../obs-autoloader.php'; // sample env
}

use Obs\ObsClient;
use Obs\ObsException;

$ak = '*** Provide your Access Key ***';

$sk = '*** Provide your Secret Key ***';

$endpoint = 'https://your-endpoint:443';

$bucketName = 'my-obs-bucket-demo';


/*
 * Constructs a obs client instance with your account for accessing OBS
 */
$obsClient = ObsClient::factory([
    'key' => $ak,
    'secret' => $sk,
    'endpoint' => $endpoint,
    'socket_timeout' => 30,
    'connect_timeout' => 10
]);

try {
    /*
     * Create bucket
     */
    printf("Create a new bucket for demo\n\n");
    $obsClient->createBucket(['Bucket' => $bucketName]);

    /*
     * First prepare folders and sub folders
     */
    $keys = [];
    $promise = null;
    $keyPrefix = 'MyObjectKey';
    $folderPrefix = 'src';
    $subFolderPrefix = 'test';

    for ($i = 0; $i < 5; $i++) {
        $key = $folderPrefix . $i . '/';
        $obsClient->putObject(['Bucket' => $bucketName, 'Key' => $key]);
        $keys[] = ['Key' => $key];
        for ($j = 0; $j < 3; $j++) {
            $subKey = $key . $subFolderPrefix . $j . '/';
            $obsClient->putObject(['Bucket' => $bucketName, 'Key' => $subKey]);
            $keys[] = ['Key' => $subKey];
        }
    }

    /*
     * Insert 2 objects in each folder
     */
    $resp = $obsClient->listObjects(['Bucket' => $bucketName]);
    foreach ($resp ['Contents'] as $content) {
        for ($k = 0; $k < 2; $k++) {
            $objectKey = $content['Key'] . $keyPrefix . $k;
            $obsClient->putObject(['Bucket' => $bucketName, 'Key' => $objectKey, 'Body' => 'Hello OBS']);
            $keys[] = ['Key' => $objectKey];
        }
    }

    /*
     * Insert 2 objects in root path
     */
    $obsClient->putObject(['Bucket' => $bucketName, 'Key' => $keyPrefix . '0', 'Body' => 'Hello OBS']);
    $obsClient->putObject(['Bucket' => $bucketName, 'Key' => $keyPrefix . '1', 'Body' => 'Hello OBS']);
    printf("Put %d objects completed.\n\n", count($keys));


    /*
     * List all objects in folder src0/
     */
    printf("List all objects in folder src0/\n\n");
    $resp = $obsClient->listObjects(['Bucket' => $bucketName, 'Prefix' => 'src0/']);
    foreach ($resp ['Contents'] as $content) {
        printf("\t%s etag[%s]\n", $content ['Key'], $content ['ETag']);
    }
    printf("\n");

    /*
     * List all objects in sub folder src0/test0/
     */

    printf("List all objects in folder src0/test0/\n\n");
    $resp = $obsClient->listObjects(['Bucket' => $bucketName, 'Prefix' => 'src0/test0/']);
    foreach ($resp ['Contents'] as $content) {
        printf("\t%s etag[%s]\n", $content ['Key'], $content ['ETag']);
    }
    printf("\n");

    /*
     * List all objects group by folder
     */
    printf("List all objects group by folder\n\n");
    $resp = $obsClient->listObjects(['Bucket' => $bucketName, 'Delimiter' => '/']);
    printf("Root path:\n");
    foreach ($resp ['Contents'] as $content) {
        printf("\t%s etag[%s]\n", $content ['Key'], $content ['ETag']);
    }
    listObjectsByPrefix($resp);
    printf("\n");

    /*
     * Delete all the objects created
     */
    $resp = $obsClient->deleteObjects([
        'Bucket' => $bucketName,
        'Objects' => $keys,
        'Quiet' => false,
    ]);

    printf("Delete results:\n\n");
    $i = 0;
    foreach ($resp['Deleteds'] as $delete) {
        printf("\tDeleteds[$i][Key]:%s,Deleted[$i][VersionId]:%s，Deleted[$i][DeleteMarker]:%s，Deleted[$i][DeleteMarkerVersionId]:%s\n",
            $delete['Key'], $delete['VersionId'], $delete['DeleteMarker'], $delete['DeleteMarkerVersionId']);
        $i++;
    }
    printf("\n");
    printf("Error results:\n\n");
    $i = 0;
    foreach ($resp['Errors'] as $error) {
        printf("\tErrors[$i][Key]:%s,Errors[$i][VersionId]:%s，Errors[$i][Code]:%s，Errors[$i][Message]:%s\n",
            $error['Key'], $error['VersionId'], $error['Code'], $error['Message']);
        $i++;
    }

} catch (ObsException $e) {
    echo 'Response Code:' . $e->getStatusCode() . PHP_EOL;
    echo 'Error Message:' . $e->getExceptionMessage() . PHP_EOL;
    echo 'Error Code:' . $e->getExceptionCode() . PHP_EOL;
    echo 'Request ID:' . $e->getRequestId() . PHP_EOL;
    echo 'Exception Type:' . $e->getExceptionType() . PHP_EOL;
} finally {
    $obsClient->close();
}


function listObjectsByPrefix($resp)
{
    global $obsClient;
    global $bucketName;
    while (!empty($resp ['CommonPrefixes'])) {
        foreach ($resp ['CommonPrefixes'] as $commonPrefix) {
            $commonPrefix = $commonPrefix['Prefix'];
            printf("Folder %s:\n", $commonPrefix);
            $resp = $obsClient->listObjects(['Bucket' => $bucketName, 'Delimiter' => '/', 'Prefix' => $commonPrefix]);
            foreach ($resp ['Contents'] as $content) {
                printf("\t%s etag[%s]\n", $content ['Key'], $content ['ETag']);
            }
            listObjectsByPrefix($resp);
        }
    }

}
